package com.xxh.test;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;
import com.xxh.utils.MqUtils;
import org.junit.jupiter.api.Test;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

/**
 * 消息生产者
 */
public class Send {
    @Test
    public void testSend() throws IOException {
        Connection connection = MqUtils.getConnection();
        //获取频道
        Channel channel = connection.createChannel();
        //频道要绑定队列
        /**
         * 第二参数：持久化队列吗？MQ重启之后队列是否保留？
         * 第三参数：独占队列吗？
         * 第四参数：是否在消费完成后自动删除？
         */
        channel.queueDeclare("hello", false, false, false, null);
        /**
         * 1 交换机名称
         * 2 队列名称
         * 3 消息传递的额外设置
         * 4 消息具体内容
         */
        channel.basicPublish("", "hello", MessageProperties.PERSISTENT_TEXT_PLAIN, "你好MQ".getBytes());
        MqUtils.close(connection, channel);

    }
}
